package org.gorson.timestamp;

import org.apache.flink.api.common.eventtime.TimestampAssigner;
import org.gorson.BO.SensorReadingBO;

public class SensorTimestampAssigner implements TimestampAssigner<SensorReadingBO> {
    @Override
    public long extractTimestamp(SensorReadingBO sensorBo, long l) {
        return sensorBo.timestamp;
    }
}
